package cn.zwx.canal.tools.utils;

import org.springframework.kafka.core.DefaultKafkaConsumerFactory;

import java.util.Map;

/**
 * @description: 自定义的消费组工聚类
 * @projectName:learn
 * @see:cn.zwx.canal.tools.utils
 * @author:zhangwenxue
 * @createTime:2021/1/12 14:56
 * @version:1.0
 */
public class KafKaRegisterConsumerFactory  extends DefaultKafkaConsumerFactory {
    public KafKaRegisterConsumerFactory(Map configs) {
        super(configs);
    }
}
